package com.apex.flink.stream;

import com.apex.flink.FlinkBaseSink;
import com.apex.flink.FlinkEnvironment;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSink;

public interface FlinkStreamSink <IN,OUT> extends FlinkBaseSink {
    DataStreamSink<OUT> outputStream(FlinkEnvironment env, DataStream<IN> dataStream);
}
